package com.intretech.tj.mqtt.pipeline;

import com.intretech.tj.global.parent.PipelineParent;
import io.vertx.mutiny.mqtt.messages.MqttPublishMessage;
import jakarta.enterprise.context.ApplicationScoped;

/**
 * 消息管道<br/>
 * key:客户端id<br/>
 * type:{@link MqttPublishMessage} 匹配该客户端发送的消息
 */
@ApplicationScoped
public class MessagePipeline extends PipelineParent<MqttPublishMessage> {
}
